use futures::stream::{self, StreamExt};

#[tokio::main]
pub async fn main() {
    let stream1 = stream::iter(vec![17, 19]);
    let stream2 = stream::iter(vec![17]);
    let mut zipped = stream1.zip(stream2);
    loop {
        futures::select!{
            res = zipped.select_next_some() => {
                println!("Zip result {res:?}");
            }
            complete => break,
        }
        
    }
}